package consumer

import (
	"context"

	"github.com/IBM/sarama"
)

func Run(ctx context.Context) {

}

type Consumer struct {
	ctx       context.Context
	isRunning bool
	group     *sarama.ConsumerGroup
}
